var mysql = require('mysql');

/*ZHJ edited*/
const pool  = mysql.createPool({
    host     : 'localhost',   // 数据库地址
    user     : 'root',    // 数据库用户
    password : 'gXa7dB8y380',  // 数据库密码
    database : 'code'  // 选中数据库
});


//数据库操作封装函数
let dbQuery = function ( sql, args ) {
    // 返回一个 Promise
    return new Promise(( resolve, reject ) => {
        pool.getConnection(function(err, connection) {
            if (err) {
                console.log("数据库连接错误");
                resolve({"err": -1})
            } else {
                connection.query(sql, args, ( err, result) => {
                    if ( err ) {
                        console.log("数据库操作错误");
                        console.log(err);
                        resolve({"err": -2})
                    } else {
                        console.log("数据库操作成功");
                        // 调用操作成功方法
                        resolve( {
                            "err": 0,
                            "result": result
                        } )
                    }
                    // 结束会话
                    connection.release()
                })
            }
        })
    })
}




module.exports.dbQuery = dbQuery;